package com.lds.memory.kafka.consumer;

import com.lds.memory.kafka.partition.Partition;

import java.util.Collection;

public class LogConsumer extends AbstractConsumer {
    public LogConsumer(Partition partition) {
        super(partition);
    }

    @Override
    public <Log> void consumer(Collection<Log> list) {
        for (Log log : list) {
            System.out.println(Thread.currentThread().getName() + ":" + log);
        }
    }
}
